e3d3daa5fa6476004ab040f093a66c13910e1bf0,app-fabric/src/main/java/com/continuuity/internal/app/runtime/distributed/DistributedWorkflowProgramRunner.java,DistributedWorkflowProgramRunner,run,#Program#ProgramOptions#,42

Before Change



    LOG.info("Launching distributed workflow: " + program.getName() + ":" + workflowSpec.getName());

    String runtimeArgs = new Gson().toJson(options.getUserArguments());
    // TODO (ENG-2526): deal with logging
    WeavePreparer preparer
      = weaveRunner.prepare(new WorkflowWeaveApplication(program, workflowSpec, hConfFile, cConfFile))
      .addLogHandler(new PrinterLogHandler(new PrintWriter(System.out)))
      .withArguments(workflowSpec.getName(),
                     String.format("--%s", RunnableOptions.JAR), program.getJarLocation().getName())
      .withArguments(workflowSpec.getName(), String.format("--%s", RunnableOptions.RUNTIME_ARGS), runtimeArgs);

    return new WorkflowWeaveProgramController(program.getName(), preparer.start()).startListen();
  }
}

After Change


    Preconditions.checkNotNull(workflowSpec, "Missing WorkflowSpecification for %s", program.getName());

    LOG.info("Launching distributed workflow: " + program.getName() + ":" + workflowSpec.getName());
    WeaveController controller = launcher.launch(new WorkflowWeaveApplication(program, workflowSpec,
                                                                              hConfFile, cConfFile));
    return new WorkflowWeaveProgramController(program.getName(), controller).startListen();
  }
}